Connection
public abstract class Connection
| Constructor Summary | |
|---|---|
| void | __construct(array config) 架构函数 读取数据库配置信息 |
| Method Summary | |
|---|---|
| Query | model(string model, string queryClass) 创建指定模型的查询对象 |
| protected abstract string | parseDsn(array config) 解析pdo连接的dsn信息 |
| abstract array | getFields(string tableName) 取得数据表的字段信息 |
| abstract array | getTables(string dbName) 取得数据库的表信息 |
| protected abstract array | getExplain(string sql) SQL性能分析 |
| array | fieldCase(array info) 对返数据表字段信息进行大小写转换出来 |
| mixed | getConfig(string config) 获取数据库的配置参数 |
| void | setConfig(string|array config, mixed value) 设置数据库的配置参数 |
| PDO | connect(array config, integer linkNum, array|bool autoConnection) 连接数据库方法 |
| void | free() 释放查询结果 |
| \PDO|false | getPdo() 获取PDO对象 |
| mixed | query(string sql, array bind, boolean master, bool|string class) 执行查询 返回数据集 |
| int | execute(string sql, array bind) 执行语句 |
| string | getRealSql(string sql, array bind) 根据参数绑定组装最终的SQL语句 便于调试 |
| protected void | bindValue(array bind) 参数绑定 支持 ['name'=>'value','id'=>123] 对应命名占位符 或者 ['value',123] 对应问号占位符 |
| protected mixed | getResult(bool|string class, bool procedure) 获得数据集 |
| protected array | procedure(bool|string class) 获得存储过程数据集 |
| mixed | transaction(callable callback) 执行数据库事务 |
| void | 启动事务 |
| void | commit() 用于非自动提交状态下面的查询提交 |
| void | rollback() 事务回滚 |
| protected bool | 是否支持事务嵌套 |
| protected string | parseSavepoint($name name) 生成定义保存点的SQL |
| protected string | parseSavepointRollBack($name name) 生成回滚到保存点的SQL |
| boolean | batchQuery(array sqlArray) 批处理执行SQL语句 批处理的指令都认为是execute操作 |
| integer | getQueryTimes(boolean execute) 获得查询次数 |
| integer | 获得执行次数 |
| void | close() 关闭数据库 |
| string | 获取最近一次查询的sql语句 |
| string | getLastInsID(string sequence) 获取最近插入的ID |
| integer | 获取返回或者影响的记录数 |
| string | getError() 获取最近的错误信息 |
| string | quote(string str, bool master) SQL指令安全过滤 |
| protected void | debug(boolean start, string sql) 数据库调试 记录当前SQL及分析性能 |
| void | listen(callable callback) 监听SQL执行 |
| protected bool | trigger(string sql, float runtime, mixed explain) 触发SQL事件 |
| protected void | initConnect(boolean master) 初始化数据库连接 |
| protected PDO | multiConnect(boolean master) 连接分布式服务器 |
public void __construct(array config)
架构函数 读取数据库配置信息
public Query model(string model, string queryClass)
创建指定模型的查询对象
protected abstract string parseDsn(array config)
解析pdo连接的dsn信息
public abstract array getFields(string tableName)
取得数据表的字段信息
public abstract array getTables(string dbName)
取得数据库的表信息
protected abstract array getExplain(string sql)
SQL性能分析
public array fieldCase(array info)
对返数据表字段信息进行大小写转换出来
public mixed getConfig(string config)
获取数据库的配置参数
public void setConfig(string|array config, mixed value)
设置数据库的配置参数
public PDO connect(array config, integer linkNum, array|bool autoConnection)
连接数据库方法
public void free()
释放查询结果
public \PDO|false getPdo()
获取PDO对象
public mixed query(string sql, array bind, boolean master, bool|string class)
执行查询 返回数据集
public int execute(string sql, array bind)
执行语句
public string getRealSql(string sql, array bind)
根据参数绑定组装最终的SQL语句 便于调试
protected void bindValue(array bind)
参数绑定 支持 ['name'=>'value','id'=>123] 对应命名占位符 或者 ['value',123] 对应问号占位符
protected mixed getResult(bool|string class, bool procedure)
获得数据集
protected array procedure(bool|string class)
获得存储过程数据集
public mixed transaction(callable callback)
执行数据库事务
public void startTrans()
启动事务
public void commit()
用于非自动提交状态下面的查询提交
public void rollback()
事务回滚
protected bool supportSavepoint()
是否支持事务嵌套
protected string parseSavepoint($name name)
生成定义保存点的SQL
protected string parseSavepointRollBack($name name)
生成回滚到保存点的SQL
public boolean batchQuery(array sqlArray)
批处理执行SQL语句 批处理的指令都认为是execute操作
public integer getQueryTimes(boolean execute)
获得查询次数
public integer getExecuteTimes()
获得执行次数
public void close()
关闭数据库
public string getLastSql()
获取最近一次查询的sql语句
public string getLastInsID(string sequence)
获取最近插入的ID
public integer getNumRows()
获取返回或者影响的记录数
public string getError()
获取最近的错误信息
public string quote(string str, bool master)
SQL指令安全过滤
protected void debug(boolean start, string sql)
数据库调试 记录当前SQL及分析性能
public void listen(callable callback)
监听SQL执行
protected bool trigger(string sql, float runtime, mixed explain)
触发SQL事件
protected void initConnect(boolean master)
初始化数据库连接
protected PDO multiConnect(boolean master)
连接分布式服务器
Class Connection